package process

import (
	"encoding/json"
	"fmt"
	"my-go-chat/message"
)

type PmsProcess struct {
	//仅面对对象思想使用
}

//这里需要涉及对方在线 和不在线 发送
func RetransMes(mes *message.Message) (err error) {
	var privateMes message.PrivateMes
	err = json.Unmarshal([]byte(mes.Data), &privateMes)
	if err != nil {
		return fmt.Errorf("反序列化私聊消息异常 : %w", err)
	}

	up, ok := UserMgr.onlineUsers[privateMes.RecUser.UserId]
	if ok { //该用户在线 直接转发就行
		data, err := json.Marshal(mes)
		if err != nil {
			return fmt.Errorf("序列化私聊消息异常 : %w", err)
		}
		SendMesToEachOnlineUser()
	}
}
